package com.storm.core.register

import com.storm.queue.model.Job
import com.storm.queue.register.AbstractTopicRegister
import org.springframework.stereotype.Service

/**
 * 将类注册为bean，然后继承AbstractTopicRegister，会自动注册为任务执行器
 * getTopic()为必须，topic名称最好单独在一处进行维护
 */
@Service
class TestRegister: AbstractTopicRegister() {
    override fun getTopic(): String {
        return "test"
    }

    override fun execute(job: Job) {
        println("执行到这里，看俺还有啥")
    }
}